package model

import "github.com/segmentio/kafka-go"

type MessModel struct {
	Key   []byte
	Value []byte
}

func ParseConsumerMess(message *MessModel, mess *kafka.Message) *MessModel {
	message.Key = mess.Key
	message.Value = mess.Value
	return message
}
